package com.neusoft.bd.myflink.mytable.step1;


import org.apache.flink.connector.datagen.table.DataGenConnectorOptions;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.*;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class TableDemo {
    public static void main(String[] args) {

//       虚拟表：通过对常规表进行二次操作得到的表
//        常规表：通过TableAPI创建的外部系统的表
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);

        StreamTableEnvironment tableEnvironment1 = StreamTableEnvironment.create(env);
//        以下表效果一样
//        但是如果需要将表存在外部系统，则必须使用createTable，createTable比较常用
//        tableEnvironment1.createTable("");
//
//        tableEnvironment1.createTemporaryTable("");
//        永久表
//        临时表

    }
}
